package com.sure0000.basicKafka.example;

import org.apache.kafka.clients.admin.AdminClient;

import java.util.Properties;

/**
 * @program: demo
 * @description: kafka 客户端
 * @author: xuyouchang@supcon.com
 * @create: 2019-11-13 14:16
 **/
public class KafkaClient {

    private AdminClient adminClient;

    public KafkaClient(Properties properties) {
        adminClient = AdminClient.create(properties);
    }

    public AdminClient getAdminClient() {
        return adminClient;
    }

}
